package com.xbongbong.pro.rabbitmq.binders;

import com.xbongbong.pro.rabbitmq.constant.ConnectorBinderConstant;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Service;

@Service("connectorConsumerBinder")
public interface ConnectorConsumerBinder {

    @Input(ConnectorBinderConstant.CONNECTOR_INPUT)
    SubscribableChannel connectorInput();

    @Input(ConnectorBinderConstant.CONNECTOR_HISTORY_DATA_INIT_INPUT)
    SubscribableChannel connectorHistoryDataInitInput();
}
